//import kotlinx.cinterop.*
//import kotlin.concurrent.AtomicInt
//
//
//@ExperimentalForeignApi
//fun main() {
//    increment()
//    incrementAtomic()
//    incrementLock()
//    var queue = Queue("testQueue")
//    var handle = queue.submitWithHandle({
//        println("queue task running")
//    })
//    queue.wait(handle)
//    queue.close()
//}
//
//private fun increment() {
//    var counter = 0
//    repeat(1000) { i ->
//        Task.submit({
//            repeat(1000) { i ->
//                counter++
//            }
//        })
//    }
//    Task.wait()
//    println("incrementNonAtomic执行完成，最终计数: $counter")
//}
//
//private fun incrementAtomic() {
//    var counter = AtomicInt(0)
//    repeat(1000) { i ->
//        Task.submit({
//            repeat(1000) { i ->
//                counter.incrementAndGet()
//            }
//        })
//    }
//    Task.wait()
//    println("incrementAtomic执行完成，最终计数: $counter")
//}
//
//private fun incrementLock() {
////    val lock = Any()
////    var counter = 0
////    repeat(10000) { i ->
////        ffrtSubmit({
////            repeat(10000) { i ->
////                synchronized(lock) {
////
////                }
////                mutex.lock()
////                counter++
////                mutex.unlock()
////            }
////        })
////    }
////    ffrtWait()
////    println("incrementLock执行完成，最终计数: $counter")
//}